package com.zxj.geekstudy.pubsub;

import lombok.extern.slf4j.Slf4j;
import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;

@Slf4j
public class CustomRedisPubSubListener implements MessageListener {
    @Override
    public void onMessage(Message message, byte[] pattern) {
        log.info("监听结果channel:{}, value:{}", new String(pattern), new String(message.getBody()));
    }
}
